package com.wyb.springcloud.demo.streamhello.controller;


import com.wyb.springcloud.demo.streamhello.stream.SinkSender;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

@RestController
public class MessageProducerController {
    @Autowired
    private SinkSender sinkSender;

    @GetMapping("/send/{msg}")
    public String send(@PathVariable("msg")  String msg) {

        sinkSender.send(msg);
        return msg;
    }

}
